b7bab9b62f8dc9c1566f8c22d20ae4e77db3bf3a,hangout-input-plugins/hangout-input-plugins-kafka/src/main/java/com/ctrip/ops/sysdev/inputs/Kafka.java,Kafka,prepare,#,102
Before Change
HashMap<String, String> consumerSettings = (HashMap<String, String>) this.config
.get("consumer_settings");
Iterator<Entry<String, String>> consumerSetting = consumerSettings
.entrySet().iterator();
while (consumerSetting.hasNext()) {
Map.Entry<String, String> entry = consumerSetting.next();
String k = entry.getKey();
String v = entry.getValue();
props.put(k, v);
}
consumer = kafka.consumer.Consumer
.createJavaConsumerConnector(new ConsumerConfig(props));
After Change
Properties props = new Properties();
HashMap<String, String> consumerSettings = (HashMap<String, String>) this.config.get("consumer_settings");
consumerSettings.entrySet().stream().forEach(entry -> props.put(entry.getKey(), entry.getValue()));
consumer = kafka.consumer.Consumer.createJavaConsumerConnector(new ConsumerConfig(props));
createProcessors();
}